package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.pojo.Point0F39;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;

/**
 * 0F39故障数据统一协议层落盘服务
 * @author hmc
 */
public interface SavePointFaultService extends Serializable {
    void save(SparkSession spark, JavaPairRDD<String, Point0F39> pair0F39RDD, long day);
}
